const express = require('express');
const router = express.Router();

const mysql=require('mysql');
const db =require('../db/db');
var con = mysql.createConnection(db.mysql);

// const mysql=require('mysql');
// // 创建链接对象
// const con = mysql.createConnection({
//     host: 'localhost',
//     user: 'root',
//     password: '123456',
//     // port: '3306',
//     database: 'login'
// })

con.connect();
var jsonWrite = function (res, ret) {
    if (typeof ret === 'undefined') {
        res.json({
            code: '1', msg: '操作失败'
        });
    }
    else {
        res.json(
            ret
        );
    }
};
console.log('数据库连接成功');


router.get('/getuser', (err, res) => {
    const sql = 'select * from adduser'; // 写你需要的sql代码，你要是不会写那我就真的没办法了
    
    // console.log(req);
    con.query(sql, function (err, rep) {
        if (err) {
            console.log('[SELECT ERROR] - ', err.message);
            return;
        }
        // rep内放的就是返回的数据，res是api传数据
        // 返回的数据需要转换成JSON格式
        res.json(rep);
    });
})

// 增加用户接口
router.post('/addUser', (req, res) => {
    var sql = 'insert into user(userName,password) values (?,?)';
    var params = req.body;
    console.log(params);
    con.query(sql, [params.username, params.password], function (err, result) {
        if (err) {
            console.log(err);
        }
        if (result) {
            jsonWrite(res, result);
        }
    })
});

router.get('/query',(req,res)=>{
    con.query('select * from user',function(err,row){
        if(err){
            console.log(err)            
        }
        // console.log(typeof row)
        let data = JSON.stringify(row)
        res.end(data)
    })
});


//导出该路由
module.exports = router;